package com.lhj.message;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;

/**
 * @author lhj
 * 
 * 1. 导入kafka KafkaAutoConfiguration 自动配置类KafkaProperties 自动配置类属性 spring.kafka 以开头
 * 2. 使用@EnableKafka 注解 开启Kafka功能
 * 3. KafkaTemplate：收发消息
 * 4. KafkaAmin: 维护主题
 * 5. @KafkaListener: 监听消息
 *    1)、消费者监听消息，需要有group-id
 *    2)、接收消息 @KafkaListener + ConsumerRecord
 * 6. 核心概念
 *    1)、分区：分散处理，1T的数据存储在若干节点
 *    2)、副本：数据备份，保证数据不丢失，将每个分区的副本保存在不同的节点当中
 *    3)、topic：主题，消息是发给某个主题
 */
@EnableKafka
@SpringBootApplication
public class MessageApplication {

	public static void main(String[] args) {
		SpringApplication.run(MessageApplication.class, args);
	}

}
